package com.roger.redis;

import redis.clients.jedis.JedisPubSub;

public class MyJedisPubSub extends JedisPubSub{

	@Override
	public void onMessage(String channel, String message) {
		System.out.println("channel="+channel+"  message="+message);
		
	}
	
	@Override
	public void onPMessage(String pattern, String channel, String message) {
		System.out.println("pattern="+pattern+"  channel="+channel+"  message="+message);
	}
	
	@Override
	public void onPSubscribe(String pattern, int arg1) {
		System.out.println("pattern="+pattern);
	}

	@Override
	public void onPUnsubscribe(String pattern, int arg1) {
		System.out.println("pattern="+pattern);
	}
	
	@Override
	public void onSubscribe(String channel, int arg1) {
		System.out.println("channel="+channel);
	}

	@Override
	public void onUnsubscribe(String channel, int arg1) {
		System.out.println("channel="+channel);
	}
}
